/**
 * @fileName: RocketMQConsumer.java
 * @author: pjf
 * @date: 2019年10月17日 下午3:17:11
 */

package com.rgs.base.rocketmq;

import com.rgs.base.rocketmq.annotation.RocketMqConsumerListenAnnotation;
import org.apache.rocketmq.common.message.MessageExt;

import java.util.function.Consumer;

/**
 * @className RocketMQConsumer.java
 * @author pjf
 * @date 2019年10月17日 下午3:17:11
 */

/**
 * @className RocketMQConsumer.java
 * @author pjf
 * @date 2019年10月17日 下午3:17:11
 */

public interface RocketMqConsumer {
    void start();

    void disponse();

    void setConsumerHandle(Consumer<MessageExt> consumerHandle);

//	void setTopicAndSubExpression(String topic, String subExpression);

    //	void setMessageModel(MessageModel messageModel);
    void setRocketMqConsumerAnnotation(RocketMqConsumerListenAnnotation rocketMqConsumerListenAnnotation);

    boolean isStarted();

//	void setSuccessTopic(String successTopic);
//
//	void setErrorTopic(String errorTopic);
}
